package com.mtiiot.fscore.inter1;

/**
 * Created by xyr on 2016/11/16.
 * kafka 客户端数据消费接口
 */
public interface KafkaConsumerService1 {

    /**
     * @param topic 主题
     * @param key 消息的主键
     * @param msg 消息内容
     * @return
     */
    public void consumeMessage(String topic, String key, String msg);
}
